package com.example.shopuser.test;

import com.alibaba.fastjson.JSONObject;
import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.common.message.Message;


public class RocketmqProducer {
    public static void main(String[] args) throws Exception {
//创建消息生产者
        DefaultMQProducer producer = new
                DefaultMQProducer("johnnyProducerGroup");
//设置NameServer地址
        producer.setNamesrvAddr("119.91.35.170:9876");
//启动生产者
        producer.start();
//构建消息对象
        Message message = new Message("johnnyTopic", "johnnyTag", "Hello RocketMQ".getBytes());
                System.out.println("生产者发出的消息为：" +
                        JSONObject.toJSONString(message));
//发送消息并接收结果
        SendResult sendResult = producer.send(message);
//打印结果信息
        System.out.println("生产者收到的发送结果信息为：" +
                JSONObject.toJSONString(sendResult));
//关闭生产者
        producer.shutdown();
    }
}
